from multiprocessing import Queue

# 初始化队列大小，默认大小2147483647
q = Queue(5)
# 添加数据
q.put(3)
q.put(2)
q.put(1)
# 添加数据不等待
q.put_nowait(0)
# 判断队列是否满
is_full = q.full()
print('判断队列是否满', is_full)
# 判断队列是否空
is_empty = q.empty()
print('判断队列是否空', is_empty)
# 获取队列数据
for i in range(3):
    data = q.get()  # 默认会阻塞等待数据传入
    # 获取数据不等待
    # q.get_nowait()
    print(data)
